//package com.agent.config;
//
///**
// * mongodb 存储会话
//*/
//
//@Component
//public class MongoChatMemoryStore implements ChatMemoryStore {
//
//    @Autowired
//    private MongoTemplate mongoTemplate;
//
//    // 查询会话
//    @Override
//    public List<ChatMessage> getMessages(Object memoryId) {
//        // 构建查询条件
//        Criteria criteria = Criteria.where("memoryId").is(memoryId);
//        Query query = new Query(criteria);
//        // 查询数据库，同时将数据存储形式转换为ChatMessages类型
//        ChatMessages chatMessages = mongoTemplate.findOne(query, ChatMessages.class);
//        if(chatMessages == null){
//            // 为空，返回空集合
//            return new LinkedList<>();
//        }
//        // 取出数据内容，将JSON转换为ChatMessage类型的集合
//        return ChatMessageDeserializer.messagesFromJson(chatMessages.getContent());
//    }
//
//    // 更新会话
//    @Override
//    public void updateMessages(Object memoryId, List<ChatMessage> messages) {
//        // 构建更新语句
//        Criteria criteria = Criteria.where("memoryId").is(memoryId);
//        Query query = new Query(criteria);
//        Update update = new Update();
//        update.set("content", ChatMessageSerializer.messagesToJson(messages));// 将集合转换为JSON
//        // 操作数据库
//        mongoTemplate.upsert(query, update, ChatMessages.class);
//    }
//
//    @Override
//    public void deleteMessages(Object memoryId) {
//        // 构建语句
//        Criteria criteria = Criteria.where("memoryId").is(memoryId);
//        Query query = new Query(criteria);
//        // 操作数据库
//        mongoTemplate.remove(query, ChatMessages.class);
//    }
//}